package com.tanjun.data.service;

/**
 * 延迟队列消息处理接口
 *
 * @param <T>
 */
public interface DelayQueueHandler<T> {

    /**
     * 获取队列名称
     *
     * @return 队列名称
     */
    String getQueueName();

    /**
     * 处理延迟队列消息
     *
     * @param msg 消息内容
     */
    void handle(T msg);

}
